package com.haruhi.bot.endpoint.ws;

import com.haruhi.bot.endpoint.ws.model.MessageBox;

import java.util.concurrent.LinkedBlockingQueue;

public class MessageQueue {

    private static final LinkedBlockingQueue<MessageBox> queue = new LinkedBlockingQueue<>();

    public static boolean offer(MessageBox messageBox){
        return queue.offer(messageBox);
    }

    public static MessageBox take() throws InterruptedException {
        return queue.take();
    }


}
